f76256539518ac44b3a7c327fc471c506f91f9b7,src/org/jgroups/protocols/UFC.java,UFC,handleDownMessage,#Event#Message#number#,86
Before Change
return down_prot.down(evt);
}
if(max_block_times != null) {
long tmp=getMaxBlockTime(length);
if(tmp > 0)
end_time.set(System.currentTimeMillis() + tmp);
}
UfcCredit cred=(UfcCredit)sent.get(dest);
After Change
return down_prot.down(evt);
}
long block_time=max_block_times != null? getMaxBlockTime(length) : max_block_time;
while(running) {
if(cred.decrementIfEnoughCredits(length, 0)) // timeout == 0: don't block